package com.leo.hadoop.map;

import com.leo.hadoop.map.*;
import com.leo.util.*;

import java.io.IOException;
import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Mapper;
import org.apache.hadoop.conf.Configuration;

/**
 * Describe class ProcessMapper here.
 *
 *
 * Created: Thu Apr 18 22:37:48 2013
 *
 * @author <a href="mailto:leo@leo-pc">Leo</a>
 * @version 1.0
 */
public class ProcessMapper extends MyMapper {

    /**
     * Creates a new <code>ProcessMapper</code> instance.
     *
     */
    public ProcessMapper() {

    }

    @Override
    public void process(Text key, Text value, Context context) throws IOException, InterruptedException {

    }

    @Override
    public Schema getOutputSchema() {
	return this.schema;
    }

    @Override
    protected void init(Configuration confj) {
    }


}
